package com.smark.sbrabbitmqfanoutproducer.work;

import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.rabbit.annotation.*;
import org.springframework.stereotype.Component;

/**
 * @author smark
 */
@Component
//1、会把申请的队列和交换机进行绑定
// 2、确定消息的模式 fanout direct topic
// 3、确定消息queue的持久性
@RabbitListener(queues = "order.queue")
public class LogWorkService {


    @RabbitHandler
    public void receiveMessages(String message){

        System.out.println("workLog------------"+message);
    }


}
